package com.example.kafkaspringboot.listener;

import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer01 {

    // 消息过滤监听
    /*@KafkaListener(topics = {"topic1"},containerFactory = "filterContainerFactory")
    public void onMessage6(ConsumerRecord<?, ?> record) {
        System.out.println(record.value());
    }*/
}
